# -*- coding: utf-8 -*-
from airflow.operators.python import PythonOperator
from .dm_start_rnk_month_detail_dt_onsuccess import main
from jms.dm.dm_start_rnk_month_detail_dt import jms_dm__dm_start_rnk_month_detail_dt


jms_dm__dm_start_rnk_month_detail_dt_success = PythonOperator(
    task_id='jms_dm__dm_start_rnk_month_detail_dt_success',
    email=['houwenlong@jtexpress.com','yl_bigdata@yl-scm.com'],
    pool='unlimited_pool',
    python_callable=main,
    op_args=['{{ execution_date | cst_ds }}', '{{ var.json.mysq_sync_status2kafka }}'],
)

jms_dm__dm_start_rnk_month_detail_dt_success << [jms_dm__dm_start_rnk_month_detail_dt]